KSQL_STREAM_CREATE_TEMP = \
"CREATE OR REPLACE STREAM {} {} WITH (kafka_topic='{}', value_format='{}', partitions=1);"

KSQL_STREAM_SCHEMA_DESC = \
"(type VARCHAR, \
  og_log STRUCT< \
      type VARCHAR, \
      account_request STRUCT< \
          market_type VARCHAR, \
          exchange VARCHAR, \
          owner VARCHAR, \
          api_version VARCHAR>, \
      event STRUCT< \
          type VARCHAR, \
          event_time VARCHAR, \
          trading_date VARCHAR, \
          exchange_type VARCHAR, \
          market_type VARCHAR, \
          proc_order_id VARCHAR, \
          external_order_id VARCHAR, \
          symbol VARCHAR, \
          native_symbol VARCHAR, \
          error_code VARCHAR, \
          error_type VARCHAR, \
          exchange_error_code VARCHAR, \
          exchange_error_msg VARCHAR>, \
      balance STRUCT< \
          exchange VARCHAR, \
          each_balance VARCHAR>, \
      position STRUCT< \
          exchange VARCHAR, \
          each_position VARCHAR>, \
      rate_limit_report_message STRUCT< \
          rate_limit_info VARCHAR, \
          num_total_hit VARCHAR, \
          last_hit_request_type VARCHAR, \
          last_hit_timestamp VARCHAR>, \
      raw_msg_id VARCHAR>, \
  telemetry STRUCT< \
      type VARCHAR, \
      latency VARCHAR, \
      tps VARCHAR> \
)"
